package demo3;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class Text02 {
    public static void main(String[] args) throws InterruptedException {
        // 创建一个阻塞队列
        BlockingQueue<Integer> queue = new LinkedBlockingQueue<>(3);
        // 向阻塞队列中添加元素
        queue.put(1);
        queue.put(2);
        queue.put(3);
        System.out.println("添加了三个元素...");
//        queue.put(4);
//        System.out.println("添加了四个元素..."); // 这句话打印不出来

        System.out.println(queue.take());
        System.out.println(queue.take());
        System.out.println(queue.take());
        System.out.println("已经取出来三个元素...");
        System.out.println(queue.take());
        System.out.println("已经取出来四个元素..."); // 这句话打印不出来
    }
}
